package com.lry.rpc;


import com.lry.message.*;
import com.lry.producer.SendResult;
import com.lry.topic.TopicPublishInfo;

import java.util.List;

public interface MqRpcService {

    SendResult sendMsg(Message msg);

    SendResult sendMsg(Message msg,int queueId);

    List<MessageExt> pullMessage(PullMessage pullMessage);

    void ack(AckMessage ackMessage);

    TopicPublishInfo tryToFindTopicPublishInfo(String topic);
}
